package cn.wolfcode.shop.message;

import javax.jms.Destination;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;

@Component
public class CreateActionProducer {

	// 专门用来发消息的对象
		@Autowired
		private JmsTemplate jmsTemplate;

		// 使用方法名来区分多个不同的Destination
		@Autowired
		@Qualifier("createActionQueue")
		private Destination createActionQueue;
//		@Autowired
//		private Destination createOrderTopic;

		/**
		 * 发送消息的方法
		 * 发送的时候需要:消息目的地和消息内容
		 * @param content
		 */
		public void sendMessage(String content) {
			//		ActiveMQQueue activeMQQueue = new ActiveMQQueue("createOrderQueue");// 每次调用都要new一个对象,耗费内存,也交给spring容器管理
			// 将消息转好成message对象发送出去
			jmsTemplate.convertAndSend(createActionQueue,content);
		}
//		public void sendMessageByTopic(String content) {
//			//		ActiveMQQueue activeMQQueue = new ActiveMQQueue("createOrderQueue");// 每次调用都要new一个对象,耗费内存,也交给spring容器管理
//			// 将消息转好成message对象发送出去
//			jmsTemplate.convertAndSend(createOrderTopic,content);
//		}
}
